package com.SparkSQL

import org.apache.spark.SparkConf
import org.apache.spark.sql.SparkSession

/**
 * Spark 连接外置Hive表
 */
object Spark05_SparkSQL_Hive {
  def main(args: Array[String]): Unit = {

    //TODO 创建Spark SQL的运行环境
    val sparkConf: SparkConf = new SparkConf().setMaster("local[*]").setAppName("SparkSQL_Hive")
    val spark: SparkSession = SparkSession.builder().config(sparkConf).getOrCreate()

    /**
     * 使用SparkSQL连接外置Hive
     * 1、拷贝Hive-size.xml 文件到 classpath 下
     * 2、启动hive的支持
     * 3、增加对应的依赖关系（包含MySQL的驱动）
     */
    spark.sql("show tables").show

    //TODO 关闭环境
    spark.close()

  }
}
